/* 
 * Quechua - the lightweight data mining framework
 *
 * Copyright (C) 2012 Marek Denis <quechua@octogan.net>
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */

#ifndef STUB_CC
#define STUB_CC

#include "../../../include/interface.h"
#include "../../../include/quechua.h"
#include "../../../include/log.h"
#include "../../channel/stdch/stdch.cc"

#include <ev++.h>
#include <cstdio>
struct ProcessorData: public DataPack {
    string_t content;
    ProcessorData(): DataPack() {LOG(DEBUG) << "ProcessorData::constructor(). PTR: " << this;};
    ~ProcessorData() { LOG(DEBUG) << "ProcessorData::destructor(). PTR: " << this;}
};

class StubProcessor: public Processor {
public:
    StubProcessor();
    ~StubProcessor();
    datapack_ptr preprocess(const datapack_ptr data);
    datapack_ptr postprocess(const datapack_ptr data);
protected:
    void init();
};

StubProcessor::StubProcessor():Processor() {
    LOG(DEBUG) << "StubProcessor createt at: " << this;
};

datapack_ptr StubProcessor::preprocess(const datapack_ptr data) {
    {LOG(DEBUG) << "StubProcessor::preprocess()";}
  ProcessorData* pack = new ProcessorData;
//  MyData* tmp_data = dynamic_cast<MyData*>(data.get());
  pack->content = "bla";


  return datapack_ptr(pack);
    
};

datapack_ptr StubProcessor::postprocess(const datapack_ptr data) {
    return datapack_ptr(new ProcessorData);
};

extern "C" Processor* create_processor() {
    return new StubProcessor();
};

extern "C" void destroy_processor(Processor* processor) {
    if(processor!=NULL)
        delete processor;
};

#endif
